package consumer

var KafkaConsumers = []Consumer{}

type Consumer interface {
	Start() error
}
